///**
// * 代号:绰绰有余 2017：厚溥
// * 文件名：WebSocket.java
// * 创建人：柯栋
// * 日期：2017年11月27日
// * 修改人：
// * 描述：
// */
//package org.setone.websocket;
//
//import java.io.IOException;
//import java.util.Set;
//import java.util.concurrent.CopyOnWriteArraySet;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnError;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.ServerEndpoint;
//
///**
// * 用途：业务模块名称
// */
//@ServerEndpoint("/websocket")
//public class WebSocket {
//	 private static final Set<WebSocket> connections = new CopyOnWriteArraySet<>();
//	 private Session session;
//
//	@OnOpen
//	public void onOpen(Session session) {
//		this.session = session;
//        connections.add(this);
//            System.out.println("webservice开启链接");
//	}
//
//	@OnClose
//	public void onClose() {
//		connections.remove(this);
//		 System.out.println("webservice关闭链接");
//	}
//
//	@OnMessage
//	public void onMessage(String message) throws IOException {
//		System.out.println(message);
//		broadcast(message);
//	}
//
//	@OnError
//	public void onError(Throwable error) {
//		 System.out.println("webservice出错");
//	}
//
//    private static void broadcast(String msg) {
//        for (WebSocket client : connections) {
//            try {
//                synchronized (client) {
//                    client.session.getBasicRemote().sendText(msg);
//                }
//            } catch (IOException e) {
//                connections.remove(client);
//                try {
//                    client.session.close();
//                } catch (IOException e1) {
//                    // Ignore
//                }
//            }
//        }
//    }
//}
